//package com.erik.lin.activemq.producer;
//
///**
// * Created by Erik on 2017/4/26.
// */
//import org.slf4j.Logger;
//import org.slf4j.LoggerFactory;
//import org.springframework.jms.core.JmsTemplate;
//import org.springframework.jms.core.MessageCreator;
//import org.springframework.stereotype.Service;
//
//import javax.annotation.Resource;
//import javax.jms.Destination;
//import javax.jms.JMSException;
//import javax.jms.Message;
//import javax.jms.Session;
//
//@Service
//public class ProducerService {
//
//    @Resource(name = "jmsQueueTemplate")
//    private JmsTemplate jmsQueueTemplate;
//    @Resource(name = "jmsTopicTemplate")
//    private JmsTemplate jmsTopicTemplate;
//
//    private Logger LOG = LoggerFactory.getLogger(ProducerService.class);
//
//    /**
//     * 向指定队列发送消息
//     */
//    public void sendMessageToQueue(Destination destination, final String msg) {
//
//        LOG.info("向队列 {} 发送了消息------------ {}", destination.toString(), msg);
//        jmsQueueTemplate.send(destination, new MessageCreator() {
//            public Message createMessage(Session session) throws JMSException {
//                return session.createTextMessage(msg);
//            }
//        });
//    }
//
//    /**
//     * 向默认队列发送消息
//     */
//    public void sendMessageToQueue(final String msg) {
//        String destination =  jmsQueueTemplate.getDefaultDestination().toString();
//        LOG.info("向队列 {} 发送了消息------------ {}", destination.toString(), msg);
//        jmsQueueTemplate.send(new MessageCreator() {
//            public Message createMessage(Session session) throws JMSException {
//                return session.createTextMessage(msg);
//            }
//        });
//
//    }
//
//    /**
//     * 向指定主题发送消息
//     */
//    public void sendMessageToTopic(Destination destination, final String msg) {
//
//        LOG.info("向主题 {} 发送了消息------------ {}", destination.toString(), msg);
//        jmsTopicTemplate.send(destination, new MessageCreator() {
//            public Message createMessage(Session session) throws JMSException {
//                return session.createTextMessage(msg);
//            }
//        });
//    }
//
//    /**
//     * 向默认主题发送消息
//     */
//    public void sendMessageToTopic(final String msg) {
//        String destination =  jmsQueueTemplate.getDefaultDestination().toString();
//        LOG.info("向主题 {} 发送了消息------------ {}", destination.toString(), msg);
//        jmsTopicTemplate.send(new MessageCreator() {
//            public Message createMessage(Session session) throws JMSException {
//                return session.createTextMessage(msg);
//            }
//        });
//
//    }
//
//}
